package cn.ocean._04delay;


import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

import java.nio.charset.StandardCharsets;

public class Producer {

   public static void main(String[] args) throws Exception{

       // 创建生产者对象，指定生产者组名
       DefaultMQProducer producer = new DefaultMQProducer("delay_group_producer");

       // 连接mq
       producer.setNamesrvAddr("127.0.0.1:9876");
       // 启动生产者
       producer.start();
       // 发送消息
       // 创建消息体
       // topic：消息主题 tags：此主题下的二级分类 body：消息的字节
       Message message = new Message("delay", "delay_tags", "我赵洋最帅".getBytes(StandardCharsets.UTF_8));
       // 设置延迟消息级别
       message.setDelayTimeLevel(3);
       // 发送消息
       SendResult sendResult = producer.send(message);
       // 发送结果
       System.out.println(sendResult);
       // 关闭生产者
       producer.shutdown();











    }
}
